9.28 读写分离/主从复制

9.28.1 读写分离

其实就是将数据库分为了主从库，一个主库用于写数据，多个从库完成读数据的操作，主从库之间通过某种机制进行数据的同步，是一种常见的数据库架构。

9.28.1.1 解决了什么问题

大多数互联网业务，往往读多写少，这时候，数据库的读会首先成为数据库的瓶颈，这时，如果我们希望能够线性的提升数据库的读性能，消除读写锁冲突从而提升数据库的写性能，那么就可以使用“分组架构”（读写分离架构）。

用一句话概括，读写分离是用来解决数据库的读性能瓶颈的。

9.28.1.2 注意事项

数据库连接池要进行区分，哪些是读连接池，哪个是写连接池，研发的难度会增加；
为了保证高可用，读连接池要能够实现故障自动转移；
主从的一致性问题需要考虑。

9.28.2 如何实现

Furion 在数据库模块设计之初，就考虑了读写分离这种情况，所以从底层就支持动态切换数据库上下文及读写操作方法约束。

读写分离操作主要使用 IMSRepository 仓储，该仓储已经为开发者提供方便的操作调用。当然也可以不使用该仓储。

下面就给大家演示如何读写多库读写操作。

9.28.2.1 创建 `主库` 数据库上下文

using Furion.DatabaseAccessor;  
using Microsoft.EntityFrameworkCore;  

namespace Furion.EntityFramework.Core  
{  
    /// <summary>  
    /// 主库数据库上下文  
    /// </summary>  
    [AppDbContext("MasterConnectionString")]  
    public class MasterDbContext : AppDbContext<MasterDbContext>  
    {  
        public MasterDbContext(DbContextOptions<MasterDbContext> options) : base(options)  
        {  
        }  
    }  
}

数据库连接字符串：

{  
  "ConnectionStrings": {  
    "MasterConnectionString": "Server=localhost;Database=Furion;User=sa;Password=000000;MultipleActiveResultSets=True;"  
  }  
}

9.28.2.2 创建 `从库` 数据库上下文

using Furion.Core;  
using Furion.DatabaseAccessor;  
using Microsoft.EntityFrameworkCore;  

namespace Furion.EntityFramework.Core  
{  
    /// <summary>  
    /// 从库数据库上下文  
    /// </summary>  
    [AppDbContext("SlaveConnectionString")]  
    public class SlaveDbContext : AppDbContext<SlaveDbContext, SlaveDbContextLocator>  
    {  
        public SlaveDbContext(DbContextOptions<SlaveDbContext> options) : base(options)  
        {  
        }  
    }  
}

特别注意多数据库操作除了默认数据库无需自定义 数据库上下文定位器，其他数据库都需要有数据库上下文定位器。如 SlaveDbContextLocator

从库数据库上下文定位器：

using Furion.DatabaseAccessor;  

namespace Furion.Core  
{  
    /// <summary>  
    /// 从库数据库上下文定位器  
    /// </summary>  
    public class SlaveDbContextLocator : IDbContextLocator  
    {  
    }  
}

数据库连接字符串：

{  
  "ConnectionStrings": {  
    "SlaveConnectionString": "Server=localhost;Database=FurSlave;User=sa;Password=000000;MultipleActiveResultSets=True;"  
  }  
}

9.28.2.3 注册 `主从库` 数据库上下文

using Furion.Core;  
using Microsoft.Extensions.DependencyInjection;  

namespace Furion.EntityFramework.Core  
{  
    [AppStartup(600)]  
    public sealed class FurEntityFrameworkCoreStartup : AppStartup  
    {  
        public void ConfigureServices(IServiceCollection services)  
        {  
            services.AddDatabaseAccessor(options =>  
            {  
                services.AddDbPool<MasterDbContext>();  
                services.AddDbPool<SlaveDbContext, SlaveDbContextLocator>();  
            });  
        }  
    }  
}

9.28.2.4 创建 `Person` 实体

由于 主从库 具有相同的数据库结构，所以实体也必须声明 主从库：

using Furion.DatabaseAccessor;  
using System.ComponentModel.DataAnnotations;  
using System.ComponentModel.DataAnnotations.Schema;  

namespace Furion.Core  
{  
    public class Person : IEntity<MasterDbContextLocator, SlaveDbContextLocator>  
    {  
        /// <summary>  
        /// 主键Id  
        /// </summary>  
        [Key]  
        [DatabaseGenerated(DatabaseGeneratedOption.Identity)]  
        public int Id { get; set; }  

        /// <summary>  
        /// 名称  
        /// </summary>  
        public string Name { get; set; }  

        /// <summary>  
        /// 年龄  
        /// </summary>  
        public int Age { get; set; }  
    }  
}

9.28.2.5 将 `Person` 转换成数据库表

创建主库数据库表：

Add-Migration v0.0.1 -Context MasterDbContext

Update-Database -Context MasterDbContext

创建从库数据库表：

Add-Migration v0.0.1 -Context SlaveDbContext

Update-Database -Context SlaveDbContext

9.28.2.6 固定主从库使用例子

using Furion.Core;  
using Furion.DatabaseAccessor;  
using Furion.DynamicApiController;  
using System.Collections.Generic;  

namespace Furion.Application  
{  
    public class PersonService : IDynamicApiController  
    {  
        /// <summary>  
        /// 可调配仓储（读写分离）  
        /// </summary>  
        private readonly IMSRepository<MasterDbContextLocator, SlaveDbContextLocator> _msRepository;  

        /// <summary>  
        /// 构造函数初始化  
        /// </summary>  
        /// <param name="msRepository"></param>  
        public PersonService(IMSRepository<MasterDbContextLocator, SlaveDbContextLocator> msRepository)  
        {  
            _msRepository = msRepository;  
        }  

        /// <summary>  
        /// 新增走主库  
        /// </summary>  
        /// <param name="person"></param>  
        /// <returns></returns>  
        public void Insert(Person person)  
        {  
            _msRepository.Master<Person>().Insert(person);  
        }  

        /// <summary>  
        /// 查询走从库  
        /// </summary>  
        /// <returns></returns>  
        public List<Person> Get()  
        {  
            return _msRepository.Slave1<Person>().AsEnumerable().ToList();  
        }  
    }  
}

9.28.2.7 `随机`或 `自定义`返回从库 ✨

在 Furion 2.4.1 + 版本新增了 IMSRepository 和 IMSRepository<TMasterDbContextLocator> 仓储类型，可以获取随机仓储或自定义仓储。使用例子如下：

配置主库 [AppDbContext] 特性的 SlaveDbContextLocators 属性，可通过构造函数最后参数传入，如：

using Furion.DatabaseAccessor;  
using Microsoft.EntityFrameworkCore;  

namespace Furion.EntityFramework.Core  
{  
    [AppDbContext("Sqlite3ConnectionString", DbProvider.Sqlite, typeof(从库定位器1), typeof(从库定位器2), typeof(从库定位器3))]  
    public class MasterDbContext : AppDbContext<MasterDbContext>  
    {  
        public MasterDbContext(DbContextOptions<MasterDbContext> options) : base(options)  
        {  
        }  
    }  
}

使用 IMSRepository 或 IMSRepository<TMasterDbContextLocator>

using Furion.Core;  
using Furion.DatabaseAccessor;  
using Furion.DynamicApiController;  
using System.Collections.Generic;  

namespace Furion.Application  
{  
    public class PersonService : IDynamicApiController  
    {  
        /// <summary>  
        /// 可调配仓储（读写分离）  
        /// </summary>  
        private readonly IMSRepository _msRepository;   // 不指定定位器，默认是 MasterDbContextLocator  

        /// <summary>  
        /// 构造函数初始化  
        /// </summary>  
        /// <param name="msRepository"></param>  
        public PersonService(IMSRepository msRepository)  
        {  
            _msRepository = msRepository;  
        }  

        /// <summary>  
        /// 新增走主库  
        /// </summary>  
        /// <param name="person"></param>  
        /// <returns></returns>  
        public void Insert(Person person)  
        {  
            _msRepository.Master<Person>().Insert(person);  
        }  

        /// <summary>  
        /// 随机从库  
        /// </summary>  
        /// <returns></returns>  
        public List<Person> Get()  
        {  
            return _msRepository.Slave<Person>().AsEnumerable().ToList();  
        }  

        /// <summary>  
        /// 自定义从库  
        /// </summary>  
        /// <returns></returns>  
        public List<Person> Get()  
        {  
            return _msRepository.Slave<Person>(() => {  
                // 这里写你的逻辑返回从库定位器  

                return 你的从库定位器;  
            }).AsEnumerable().ToList();  
        }  
    }  
}

特别说明IMSRepository 不带泛型默认指的是 IMSRepository<TMasterDbContextLocator>，如需泛型版本，则使用 IMSRepository<定位器>